package com.project.queue.tool;

import lombok.extern.slf4j.Slf4j;

import java.util.Objects;

/**
 * @author mengxj
 */
@Slf4j
public class EmptyQueue extends BaseQueue {

    private static EmptyQueue instance;

    public static BaseQueue getInstance(){
        if(Objects.isNull(instance)){
            synchronized (EmptyQueue.class){
                if(Objects.isNull(instance)){
                    instance = new EmptyQueue();
                }
            }
        }
        return instance;
    }

    @Override
    public void send(String queue, String value) {
        log.warn("当前未正确配置队列类型，无法使用 发送数据 功能，请正确配置 type.queue参数(rabbitMq kafka)");
    }
}
